/*
  封装通用的数据库操作函数
*/
function operateDb (sql, params) {
  return new Promise(function (resolve, reject) {
    // 1、导入包
    const mysql = require('mysql')

    // 2、链接上数据库(配置参数)
    const cn = mysql.createConnection({
      // 数据库所在计算机的域名或者IP地址
      host: 'localhost',
      // 数据库的端口
      port: 3307,
      // 数据库名称
      database: '115',
      // 账号信息
      user: 'root',
      password: 'admin123'
    })

    // 3、执行链接操作
    cn.connect()

    // 4、操作数据库
    // let sql = 'select * from myuser where id = ?'
    cn.query(sql, params, function (err, res) {
      if (err) {
        // 出错了
        reject(err.message)
      } else {
        // 正常
        resolve(res)
      }
    })

    // 5、关闭数据库
    cn.end()
  })
}

module.exports.operateDb = operateDb